package com.k8.common.executor.blockingQueue;

import java.util.Queue;

public class AbortPolicy<E> implements Rejector<E> {
    @Override
    public void reject(E e, Queue<E> queue) {
        throw new RejectException("BlockingQueue is oom, size of queue:"+queue.size());
    }
}
